var express = require("express");
var http = require("http");
var WebSocket = require("ws");

var app = express();
app.use(express.static(__dirname));

var server = http.createServer(app);
var wss = new WebSocket.Server({ server });

wss.on("connection", function connection(ws) {
  console.log("链接成功！");
  ws.on("message", function incoming(data) {
    /**
     * 把消息发送到所有的客户端
     * wss.clients获取所有链接的客户端
     */
    wss.clients.forEach(function each(client) {
      client.send(data);
    });
  });
});

server.listen(3000, function listening() {
  console.log("服务器启动成功！");
});
// var express = require("express"),
//   app = express(),
//   server = require("http").createServer(app);

// server.listen(3000);

// app.get("/", function (req, res) {
//   res.sendFile(__dirname + "/webrtc.html");
// });

// var WebSocketServer = require("ws").Server,
//   wss = new WebSocketServer({ server: server });

// const connection = {};

// // 有socket连入
// wss.on("connection", function (ws) {
//   // 转发收到的消息
//   ws.on("message", function (message) {
//     console.log("收到消息");
//     //var json = JSON.parse(message);
//     ws.send(message, function (error) {
//       console.log(error);
//     });
//     // if (json.type === "offer") {
//     //   connection[json.type] = ws;
//     //   ws.send(message, function (error) {
//     //     console.log(error);
//     //   });
//     // }
//   });
// });
